/*
package streaming

import org.apache.kafka.clients.consumer.ConsumerRecord
import org.apache.spark.SparkConf
import org.apache.spark.streaming.dstream.InputDStream
import org.apache.spark.streaming.kafka010.{ConsumerStrategies, KafkaUtils, LocationStrategies}
import org.apache.spark.streaming.{Seconds, StreamingContext}


object streaming_kfka {
  def main(args: Array[String]): Unit = {
    val conf = new SparkConf()
      .setAppName("_01StreamingWordCountApp")
      .setMaster("local[*]")
    val bi=Seconds(2)
    new StreamingContext(conf,bi)
    val messages: InputDStream[ConsumerRecord[String, String]] =  KafkaUtils.createDirectStream(ssc,
      LocationStrategies.PreferConsistent,
     /* ConsumerStrategies.Subscribe[String, String](topics, kafkaParams),
      myPerPartitionConfig)*/
  }

}
*/
